package cn.doitedu.dfdemo

import org.apache.spark.sql.{DataFrame, SparkSession}

/**
 * @Date 22.4.9
 * @Created by HANGGE
 * @Description
 *             获取SQL编程的入口
 */
object Demo02 {
  def main(args: Array[String]): Unit = {
    val session = SparkSession
      .builder()
      .master("local[*]")
      .appName("获取 spark-sql环境")
      .config("", "")
      // 添加对hive的支持
      // .enableHiveSupport()
      .getOrCreate()


    val frame1: DataFrame = session.read.csv("")
    val frame2: DataFrame = session.read.json("")
    val frame3: DataFrame =  session.read.orc("")
    val frame4: DataFrame = session.read.parquet("")
    val frame5: DataFrame = session.read.text("")



     // 1 展示数据
    frame1.show()
    // 2 打印结构
    frame1.printSchema()
    // 3  使用自带的方法处理
    frame1.where("").orderBy("").limit(2)
    // 4 使用标准的SQL语句
        //   1) 注册视图
        //   2) 编写SQL语句
    frame1.createTempView("tb_x")
    session.sql("select * from tb_x where  id > 10 and age < 30")




  }
}
